package com.ydl.learning.flink.demo.transformations

import com.ydl.learning.flink.demo.Utils
import org.apache.flink.api.scala._
/**
 * union时必须是同类型的dataset才能union
 *
 * @author ydl
 * @since 2020/10/12
 */
object UnionDemo extends App with Utils {
  val input1 = env.fromElements(1,2,3)
  val input2 = env.fromElements(4,5,6)
  val input3 = env.fromElements(7,8,9)
  input1.union(input2).union(input3).print()
}
